package com.fm._1single;

import com.fm.util.ConnectionUtil;
import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;

public class SendMsg {
    public static void main(String[] args) throws Exception {
        String msg = "Hello HuangDaoJun!";
        Connection connection = ConnectionUtil.getConnection();
        Channel channel = connection.createChannel();
        //定义队列(使⽤Java代码在MQ中新建⼀个队列)
        //参数1：定义的队列名称
        //参数2：队列中的数据是否持久化（如果选择了持久化）
        //参数3: 是否排外（当前队列是否为当前连接私有）
        //参数4：⾃动删除（当此队列的连接数为0时，此队列会销毁（⽆论队列中是否还有数据））
        //参数5：设置当前队列的参数
        channel.queueDeclare("queue1", false, false, false, null);
        //参数1：交换机名称，如果直接发送信息到队列，则交换机名称为""
        //参数2：⽬标队列名称
        //参数3：设置当前这条消息的属性（设置过期时间 10）
        //参数4：消息的内容
        channel.basicPublish("", "queue1", null, msg.getBytes());
        System.out.println("发送：" + msg);
        channel.close();
        connection.close();
    }
}